package com.dtwave.lnstreaming.filter.function;

import org.apache.flink.api.common.functions.FilterFunction;

public class NotNullFilterFunction<T>  implements FilterFunction<T> {
    @Override
    public boolean filter(T t) throws Exception {
        return t != null;
    }
}
